package com.ojoin.ojoin.eb_spider.service.impl;

import com.ojoin.ojoin.eb_spider.bean.CiMingUserOrder;
import com.ojoin.ojoin.eb_spider.service.QueueService;
import com.ojoin.trade.common.utils.LogUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * Created by liaowuhen on 2017/3/22.
 */
@Service("CiMingQueue")
public class CiMingQueueServiceImpl<CiMingUserOrder> extends QueueServiceImpl<CiMingUserOrder> {
    BlockingQueue<CiMingUserOrder> basket = new LinkedBlockingQueue<>(100);
    private static Logger log = LoggerFactory.getLogger(CiMingQueueServiceImpl.class);
    @Override
    public BlockingQueue<CiMingUserOrder> getQueue() {
        return basket;
    }
}
